package com.workcell.workdata.xthings.kafka.content.impl;

import com.workcell.workdata.xthings.constant.KafKaTopicConstant;
import com.workcell.workdata.xthings.kafka.content.MqService;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.stereotype.Component;

import java.util.Objects;

/**
 * @Author 廖博文
 * @Date 2023/5/25 11:57
 * @Description 处理博文测试主题
 */
@Slf4j
@Component(KafKaTopicConstant.DEMO_BO)
public class KafkaDemoServiceImpl implements MqService {

	@Override
	public void handlerKafkaMessage(ConsumerRecord<Object, Objects> consumerRecord) {
		log.info("博文测试主题收到消息了：{}", consumerRecord.value());
	}

}
